package com.vcg.neo4j.demo.rxjava;

import org.junit.Test;
import rx.Scheduler;
import rx.functions.Action0;
import rx.schedulers.Schedulers;

/**
 * Created by wuyu on 2016/7/31.
 */
public class SchedulersTest {

    @Test
    public void testCreateWorker(){
        Scheduler.Worker worker = Schedulers.newThread().createWorker();
        worker.schedule(() -> System.err.println("开始"));
        worker.unsubscribe();
    }
}
